Java Socket 连接池 ：

Java Socket 连接池 ：

目的 为了提高 服务器的并发性能

开源好伟大 ，再次感谢不吝惜自己代码的大拿们，对个人用c++ 写服务器有很大帮助，大大提高了服务器的吞吐量。

package com.nielsenccdata.lbr.core.socket;

import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;import java.net.SocketException;import java.util.concurrent.ArrayBlockingQueue;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.RejectedExecutionException;import java.util.concurrent.SynchronousQueue;import java.util.concurrent.ThreadPoolExecutor;import java.util.concurrent.TimeUnit;

import org.slf4j.Logger;import org.slf4j.LoggerFactory;

/*** * 创建socketconnect的对象，该处是socket连接池及缓冲池* * @author sunny.sun* @version 1.0* */public class SocketServerManager extends Thread {

private static final Logger logger = LoggerFactory.getLogger(SocketServerManager.class);/*** 端口号*/private int port;

/*** 最大连接数*/private int max_conn;

/*** 缓冲区大小* */private int max_cache;

/*** socket 超时时间* */private int timeout;

/*** server对象*/private ServerSocket server;

/*** 线程池对象*/private ExecutorService exService;

public int getMax_cache() {return max_cache;}

public void setMax_cache(int max_cache) {this.max_cache = max_cache;}

public int getTimeout() {return timeout;}

public void setTimeout(int timeout) {this.timeout = timeout;}

public int getPort() {return port;}

public void setPort(int port) {this.port = port;}

public int getMax_conn() {return max_conn;}

public void setMax_conn(int max_conn) {this.max_conn = max_conn;}

public ServerSocket getServer() {return server;}

/*** * 该构造方法提供设置最大连接数，最大缓存数，超时时间，此处把socket服务端作为一个单独进程；* 而把socket连接进程放置到线程池和缓存池，以提高性能* * @param port* 端口号* @param max_conn* 最大连接池* @param max_cache* 最大缓存池* @param timeout* 超时时间*/public SocketServerManager(int port, int max_conn, int max_cache,int timeout) {

this.port = port;this.max_conn = max_conn;this.timeout = timeout